package com.app.conf.info;

import java.util.ArrayList;
import java.util.HashMap;
import java.util.List;
import java.util.Map;

public class Conf
{
	/**
	 * 网站根目录
	 * **/
	public static String www = "/pub";
	
	/**
	 * 拓展配置
	 * **/
	private static Map<String,String> extendsConfig = new HashMap<String, String>();
	
	static
	{
		//kafka服务器
		extendsConfig.put("KafkaConsumptionHost", "kafka.kafka-system:9092");
		
		//kafka接收组
		extendsConfig.put("kafkaGroupId", "test_group");
	}
	
	public static Map<String,String> getExtendsConfig(){return extendsConfig;}
	
	
	
	//kafka消费队列
	private static List<Map<String,String>> kafkaConsumeList = new ArrayList<Map<String,String>>();
	
	private static Map<String,String> test                   = new HashMap<String,String>();//更新商品价格

	public static final String kfkTest = "test";//名称

	static
	{
		test.put("name", kfkTest);//主题名称
		test.put("methodName", "run");//调用方法
		test.put("num", "1");//线程数
		test.put("className", "com.app.console.TestConsole");//调用类
		kafkaConsumeList.add(test);
	}

	public static List<Map<String,String>> getKafkaConsumeList()
	{
		return kafkaConsumeList;
	}
	
}